🎯 other 流程圖

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA Services Module\n統一的服務模組包\n']
    n4[from __future__ import annotations]
    n1 --> n3
    n3 --> n4
    n4 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA Common - 通用模組\n\n這個包包含了 AIVA 系統中所有服務共...]
    n4[__version__ = '1.0.0']
    n5[import contextlib]
    n6[from .enums import AccessDecision, AssetExposure, ...]
    n7[with contextli...]
    n8[from .schemas import AivaMessage, Asset, Authentic...]
    n9[__all__ = ['ModuleName', &amp...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[import os]
    n5[from functools import lru_cache]
    n6[from pydantic import BaseModel]
    n7[class Settings(...)]
    n8[def get_settings(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA Common Enums Package\n\n此套件提供了 AIVA 微...]
    n4[from .assets import AssetExposure, AssetStatus, As...]
    n5[from .common import Confidence, ErrorCategory, Rem...]
    n6[from .modules import CodeQualityMetric, LanguageFr...]
    n7[from .security import AccessDecision, AttackPathEd...]
    n8[__all__ = ['AccessDecision', ...]
    n9[__version__ = '2.1.0']
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n資產管理相關枚舉 - 資產類型、環境、合規等\n']
    n4[from __future__ import annotations]
    n5[from enum import Enum]
    n6[class BusinessCriticality(...)]
    n7[class Environment(...)]
    n8[class AssetType(...)]
    n9[class AssetStatus(...)]
    n10[class DataSensitivity(...)]
    n11[class AssetExposure(...)]
    n12[class ComplianceFramework(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n通用枚舉 - 狀態、級別、類型等基礎枚舉\n']
    n4[from __future__ import annotations]
    n5[from enum import Enum]
    n6[class Severity(...)]
    n7[class Confidence(...)]
    n8[class TaskStatus(...)]
    n9[class TestStatus(...)]
    n10[class ScanStatus(...)]
    n11[class ThreatLevel(...)]
    n12[class RiskLevel(...)]
    n13[class RemediationStatus(...)]
    n14[class ErrorCategory(...)]
    n15[class StoppingReason(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n模組相關枚舉 - 模組名稱、主題等\n']
    n4[from __future__ import annotations]
    n5[from enum import Enum]
    n6[class ProgrammingLanguage(...)]
    n7[class LanguageFramework(...)]
    n8[class CodeQualityMetric(...)]
    n9[class ModuleName(...)]
    n10[class Topic(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n安全測試相關枚舉 - 漏洞、攻擊、權限等\n']
    n4[from __future__ import annotations]
    n5[from enum import Enum]
    n6[class VulnerabilityByLanguage(...)]
    n7[class SecurityPattern(...)]
    n8[class VulnerabilityType(...)]
    n9[class VulnerabilityStatus(...)]
    n10[class Location(...)]
    n11[class SensitiveInfoType(...)]
    n12[class IntelSource(...)]
    n13[class IOCType(...)]
    n14[class RemediationType(...)]
    n15[class Permission(...)]
    n16[class AccessDecision(...)]
    n17[class PostExTestType(...)]
    n18[class PersistenceType(...)]
    n19[class Exploitability(...)]
    n20[class AttackPathNodeType(...)]
    n21[class AttackPathEdgeType(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA Common Models - 共享基礎模型\n\n此文件已被棄用，所有類...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any]
    n7[from pydantic import BaseModel, Field, field_valid...]
    n8[from .enums import ModuleName, Topic]
    n9[class MessageHeader(...)]
    n10[class AivaMessage(...)]
    n11[class Authentication(...)]
    n12[class RateLimit(...)]
    n13[class CVSSv3Metrics(...)]
    n14[class CVEReference(...)]
    n15[class CWEReference(...)]
    n16[class CAPECReference(...)]
    n17[class SARIFLocation(...)]
    n18[class SARIFResult(...)]
    n19[class SARIFRule(...)]
    n20[class SARIFTool(...)]
    n21[class SARIFRun(...)]
    n22[class SARIFReport(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n22
    n22 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['AIVA Message Queue (MQ) abstraction ...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[import logging]
    n7[from abc import ABC, abstractmethod]
    n8[from collections.abc import AsyncIterator]
    n9[from dataclasses import dataclass]
    n10[from typing import TYPE_CHECKING, Any]
    n11[from .config import get_settings]
    n12[from .enums import Topic]
    n13{if TYPE_CHECKING}
    n14[import aio_pika]
    n15[try]
    n16[import aio_pika]
    n17[]
    n18[except ModuleNotFou...]
    n19[aio_pika = None]
    n20[]
    n21[logger = logging.getLogger(__...]
    n22[class MQMessage(...)]
    n23[class AbstractBroker(...)]
    n24[class RabbitBroker(...)]
    n25[class InMemoryBroker(...)]
    n26[def get_broker(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 -->|Yes| n14
    n13 -->|No| n15
    n14 --> n20
    n15 --> n16
    n15 --> n18
    n16 --> n17
    n17 --> n20
    n18 --> n19
    n19 --> n17
    n20 --> n21
    n21 --> n22
    n22 --> n23
    n23 --> n24
    n24 --> n25
    n25 --> n26
    n26 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA Common Schemas Package\n\n此套件提供了 AIVA...]
    n4[from .ai import AIExperienceCreatedEvent, AIModelD...]
    n5[from .assets import AssetInventoryItem, AssetLifec...]
    n6[from .base import Asset, Authentication, Execution...]
    n7[from .enhanced import EnhancedAttackPath, Enhanced...]
    n8[from .findings import AIVerificationRequest, AIVer...]
    n9[from .languages import AILanguageModel, CodeQualit...]
    n10[from .messaging import AIVACommand, AIVAEvent, Aiv...]
    n11[from .references import CVEReference, CWEReference...]
    n12[from .risk import AttackPathEdge, AttackPathNode, ...]
    n13[from .system import ModelTrainingResult, SessionSt...]
    n14[from .tasks import APISchemaPayload, APISecurityTe...]
    n15[from .telemetry import AdaptiveBehaviorInfo, Early...]
    n16[__all__ = ['MessageHeader', &...]
    n17[__version__ = '2.1.0']
    n18[__schema_version__ = '1.0']
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAI 相關 Schema\n\n此模組定義了所有 AI 驅動功能相關的資料模型，包括...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any, Literal]
    n7[from pydantic import BaseModel, Field, field_valid...]
    n8[from ..enums import VulnerabilityType]
    n9[class CVSSv3Metrics(...)]
    n10[class AttackStep(...)]
    n11[class AttackPlan(...)]
    n12[class TraceRecord(...)]
    n13[class PlanExecutionMetrics(...)]
    n14[class PlanExecutionResult(...)]
    n15[class ModelTrainingConfig(...)]
    n16[class AITrainingStartPayload(...)]
    n17[class AITrainingProgressPayload(...)]
    n18[class RAGKnowledgeUpdatePayload(...)]
    n19[class RAGQueryPayload(...)]
    n20[class ExperienceSample(...)]
    n21[class EnhancedVulnerability(...)]
    n22[class SARIFLocation(...)]
    n23[class SARIFResult(...)]
    n24[class SARIFRule(...)]
    n25[class SARIFTool(...)]
    n26[class SARIFRun(...)]
    n27[class SARIFReport(...)]
    n28[class AITrainingCompletedPayload(...)]
    n29[class AIExperienceCreatedEvent(...)]
    n30[class AITraceCompletedEvent(...)]
    n31[class AIModelUpdatedEvent(...)]
    n32[class AIModelDeployCommand(...)]
    n33[class RAGResponsePayload(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n22
    n22 --> n23
    n23 --> n24
    n24 --> n25
    n25 --> n26
    n26 --> n27
    n27 --> n28
    n28 --> n29
    n29 --> n30
    n30 --> n31
    n31 --> n32
    n32 --> n33
    n33 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAPI 安全測試相關 Schema\n\n此模組定義了 API 安全測試相關的資料模...]
    n4[from __future__ import annotations]
    n5[__all__ = []]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n資產與 EASM 相關 Schema\n\n此模組定義了資產探索、資產生命週期管理、...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any]
    n7[from pydantic import BaseModel, Field]
    n8[from ..enums import AssetExposure, AssetType, Busi...]
    n9[from .references import TechnicalFingerprint]
    n10[class AssetLifecyclePayload(...)]
    n11[class VulnerabilityLifecyclePayload(...)]
    n12[class VulnerabilityUpdatePayload(...)]
    n13[class DiscoveredAsset(...)]
    n14[class AssetInventoryItem(...)]
    n15[class EASMAsset(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n基礎 Schema 模型\n\n此模組包含所有基礎的資料模型，這些模型會被其他 Sc...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from pydantic import BaseModel, Field, field_valid...]
    n7[from ..enums import ModuleName]
    n8[class MessageHeader(...)]
    n9[class Authentication(...)]
    n10[class RateLimit(...)]
    n11[class ScanScope(...)]
    n12[class Asset(...)]
    n13[class Summary(...)]
    n14[class Fingerprints(...)]
    n15[class ExecutionError(...)]
    n16[class RiskFactor(...)]
    n17[class TaskDependency(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nEnhanced 版本 Schemas\n\n此模組定義了各種增強版本的資料模型,提...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any]
    n7[from pydantic import BaseModel, Field, HttpUrl, fi...]
    n8[from ..enums import ModuleName, Severity, TestStat...]
    n9[from .ai import CVSSv3Metrics, EnhancedVulnerabili...]
    n10[from .base import RiskFactor, TaskDependency]
    n11[from .findings import FindingEvidence, FindingImpa...]
    n12[class EnhancedFindingPayload(...)]
    n13[class EnhancedScanScope(...)]
    n14[class EnhancedScanRequest(...)]
    n15[class EnhancedFunctionTaskTarget(...)]
    n16[class EnhancedIOCRecord(...)]
    n17[class EnhancedRiskAssessment(...)]
    n18[class EnhancedAttackPathNode(...)]
    n19[class EnhancedAttackPath(...)]
    n20[class EnhancedTaskExecution(...)]
    n21[class EnhancedVulnerabilityCorrelation(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n漏洞發現相關 Schema\n\n此模組包含與漏洞發現、證據收集、影響評估等相關的資...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any]
    n7[from pydantic import BaseModel, Field, field_valid...]
    n8[from ..enums import Confidence, Severity, Vulnerab...]
    n9[class Vulnerability(...)]
    n10[class Target(...)]
    n11[FindingTarget = Target]
    n12[class FindingEvidence(...)]
    n13[class FindingImpact(...)]
    n14[class FindingRecommendation(...)]
    n15[class FindingPayload(...)]
    n16[class SensitiveMatch(...)]
    n17[class JavaScriptAnalysisResult(...)]
    n18[class VulnerabilityCorrelation(...)]
    n19[class CodeLevelRootCause(...)]
    n20[class SASTDASTCorrelation(...)]
    n21[class AIVerificationRequest(...)]
    n22[class AIVerificationResult(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n22
    n22 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n程式語言分析和多語言支援的 Schema\n支援 Go, Rust, Java, C...]
    n4[from pydantic import BaseModel, Field]
    n5[from ..enums import CodeQualityMetric, LanguageFra...]
    n6[class LanguageDetectionResult(...)]
    n7[class LanguageSpecificVulnerability(...)]
    n8[class MultiLanguageCodebase(...)]
    n9[class LanguageSpecificScanConfig(...)]
    n10[class CrossLanguageAnalysis(...)]
    n11[class LanguageSpecificPayload(...)]
    n12[class AILanguageModel(...)]
    n13[class CodeQualityReport(...)]
    n14[class LanguageInteroperability(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n訊息佇列相關 Schema\n\n此模組定義了訊息佇列系統使用的標準信封格式。\n&...]
    n4[from __future__ import annotations]
    n5[from typing import Any]
    n6[from pydantic import BaseModel, Field]
    n7[from ..enums import Topic]
    n8[from .base import MessageHeader]
    n9[class AivaMessage(...)]
    n10[class AIVARequest(...)]
    n11[class AIVAResponse(...)]
    n12[class AIVAEvent(...)]
    n13[class AIVACommand(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n參考資料 Schemas\n\n此模組定義了各種標準參考資料的數據模型，包括 CVE...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any]
    n7[from pydantic import BaseModel, Field]
    n8[from ..enums import Confidence, Severity]
    n9[class CVEReference(...)]
    n10[class CWEReference(...)]
    n11[class TechnicalFingerprint(...)]
    n12[class VulnerabilityDiscovery(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n風險評估與攻擊路徑分析 Schema\n\n此模組定義了風險評估、攻擊路徑分析等相關...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any]
    n7[from pydantic import BaseModel, Field]
    n8[from ..enums import AssetExposure, AttackPathEdgeT...]
    n9[class RiskAssessmentContext(...)]
    n10[class RiskAssessmentResult(...)]
    n11[class RiskTrendAnalysis(...)]
    n12[class AttackPathNode(...)]
    n13[class AttackPathEdge(...)]
    n14[class AttackPathPayload(...)]
    n15[class AttackPathRecommendation(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n系統和編排相關 Schemas\n\n此模組定義了系統編排、會話管理、任務隊列、We...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any]
    n7[from pydantic import BaseModel, Field, field_valid...]
    n8[from ..enums import ModuleName]
    n9[class SessionState(...)]
    n10[class ModelTrainingResult(...)]
    n11[class TaskQueue(...)]
    n12[class EnhancedModuleStatus(...)]
    n13[class SystemOrchestration(...)]
    n14[class WebhookPayload(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n任務相關 Schema\n\n此模組定義了所有類型的任務負載 (Payloa...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any]
    n7[from pydantic import BaseModel, Field, HttpUrl, fi...]
    n8[from ..enums import Confidence, IntelSource, IOCTy...]
    n9[from .base import Asset, Authentication, Fingerpri...]
    n10[class ScanStartPayload(...)]
    n11[class ScanCompletedPayload(...)]
    n12[class FunctionTaskTarget(...)]
    n13[class FunctionTaskContext(...)]
    n14[class FunctionTaskTestConfig(...)]
    n15[class FunctionTaskPayload(...)]
    n16[class FeedbackEventPayload(...)]
    n17[class TaskUpdatePayload(...)]
    n18[class ConfigUpdatePayload(...)]
    n19[class ThreatIntelLookupPayload(...)]
    n20[class ThreatIntelResultPayload(...)]
    n21[class AuthZCheckPayload(...)]
    n22[class AuthZAnalysisPayload(...)]
    n23[class AuthZResultPayload(...)]
    n24[class RemediationGeneratePayload(...)]
    n25[class RemediationResultPayload(...)]
    n26[class PostExTestPayload(...)]
    n27[class PostExResultPayload(...)]
    n28[class BizLogicTestPayload(...)]
    n29[class BizLogicResultPayload(...)]
    n30[class APISchemaPayload(...)]
    n31[class APITestCase(...)]
    n32[class APISecurityTestPayload(...)]
    n33[class EASMDiscoveryPayload(...)]
    n34[class EASMDiscoveryResult(...)]
    n35[class StandardScenario(...)]
    n36[class ScenarioTestResult(...)]
    n37[class ExploitPayload(...)]
    n38[class TestExecution(...)]
    n39[class ExploitResult(...)]
    n40[class TestStrategy(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n22
    n22 --> n23
    n23 --> n24
    n24 --> n25
    n25 --> n26
    n26 --> n27
    n27 --> n28
    n28 --> n29
    n29 --> n30
    n30 --> n31
    n31 --> n32
    n32 --> n33
    n33 --> n34
    n34 --> n35
    n35 --> n36
    n36 --> n37
    n37 --> n38
    n38 --> n39
    n39 --> n40
    n40 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n遙測與監控相關 Schema\n\n此模組定義了模組狀態、心跳、性能指標等監控相關的...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any]
    n7[from pydantic import BaseModel, Field, field_valid...]
    n8[from ..enums import ErrorCategory, ModuleName, Sev...]
    n9[class HeartbeatPayload(...)]
    n10[class ModuleStatus(...)]
    n11[class FunctionTelemetry(...)]
    n12[class ErrorRecord(...)]
    n13[class OastCallbackDetail(...)]
    n14[class EarlyStoppingInfo(...)]
    n15[class AdaptiveBehaviorInfo(...)]
    n16[class EnhancedFunctionTelemetry(...)]
    n17[class FunctionExecutionResult(...)]
    n18[class OastEvent(...)]
    n19[class OastProbe(...)]
    n20[class SIEMEventPayload(...)]
    n21[class NotificationPayload(...)]
    n22[class SIEMEvent(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n22
    n22 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from .ids import new_id]
    n4[from .logging import get_logger]
    n5[__all__ = ['new_id', &&#3...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nDeduplication utilities for AIVA Platform....]
    n4[from .dedupe import DeDup, compute_fingerprint]
    n5[__all__ = ['DeDup', &&#35...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nDeduplication system for vulnerability fin...]
    n4[from __future__ import annotations]
    n5[import hashlib]
    n6[import json]
    n7[import logging]
    n8[import sqlite3]
    n9[import threading]
    n10[import time]
    n11[import weakref]
    n12[from collections.abc import Mapping]
    n13[from pathlib import Path]
    n14[from typing import Any]
    n15[logger = logging.getLogger(__...]
    n16[def compute_fingerprint(...)]
    n17[class DeDup(...)]
    n18[fp = compute_fingerprint]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[import uuid]
    n5[def new_id(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[import logging]
    n5[import sys]
    n6[def get_logger(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nNetwork utilities for AIVA Platform.\n\nPr...]
    n4[from .backoff import RetryingAsyncClient, jitter_b...]
    n5[from .ratelimit import RateLimiter, TokenBucket]
    n6[__all__ = ['RateLimiter', &am...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nRetry and backoff utilities for network re...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[import logging]
    n7[import random]
    n8[from collections.abc import Callable, Sequence]
    n9[from typing import Any]
    n10[import httpx]
    n11[logger = logging.getLogger(__...]
    n12[BackoffCallable = Callable[..., float]]
    n13[def jitter_backoff(...)]
    n14[def _resolve_backoff(...)]
    n15[class RetryingAsyncClient(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nRate limiter with Token Bucket algorithm, ...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[import contextlib]
    n7[import json]
    n8[import logging]
    n9[import os]
    n10[import re]
    n11[import threading]
    n12[import time]
    n13[from email.utils import parsedate_to_datetime]
    n14[from pathlib import Path]
    n15[from typing import Any]
    n16[logger = logging.getLogger(__...]
    n17[class TokenBucket(...)]
    n18[class RateLimiter(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nCore service module for AIVA.\n\nThis modu...]
    n4[from __future__ import annotations]
    n5[from ..aiva_common.enums import Severity, TaskStat...]
    n6[from .ai_models import AIModelDeployCommand, AIMod...]
    n7[from .models import AttackPathEdge, AttackPathNode...]
    n8[__all__ = ['ExecutionContext'...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA AI System Models - AI智能系統模組\n\n此文件包含A...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any]
    n7[from pydantic import BaseModel, Field]
    n8[from ..aiva_common.enums import Confidence, Module...]
    n9[class AIVerificationRequest(...)]
    n10[class AIVerificationResult(...)]
    n11[class AITrainingStartPayload(...)]
    n12[class AITrainingProgressPayload(...)]
    n13[class AITrainingCompletedPayload(...)]
    n14[class AIExperienceCreatedEvent(...)]
    n15[class AITraceCompletedEvent(...)]
    n16[class AIModelUpdatedEvent(...)]
    n17[class AIModelDeployCommand(...)]
    n18[class AttackStep(...)]
    n19[class AttackPlan(...)]
    n20[class PlanExecutionMetrics(...)]
    n21[class PlanExecutionResult(...)]
    n22[class TraceRecord(...)]
    n23[class ExperienceSample(...)]
    n24[class SessionState(...)]
    n25[class ModelTrainingConfig(...)]
    n26[class ModelTrainingResult(...)]
    n27[class StandardScenario(...)]
    n28[class ScenarioTestResult(...)]
    n29[class RAGKnowledgeUpdatePayload(...)]
    n30[class RAGQueryPayload(...)]
    n31[class RAGResponsePayload(...)]
    n32[class AIVARequest(...)]
    n33[class AIVAResponse(...)]
    n34[class AIVAEvent(...)]
    n35[class AIVACommand(...)]
    n36[__all__ = ['AIVerificationRequ...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n22
    n22 --> n23
    n23 --> n24
    n24 --> n25
    n25 --> n26
    n26 --> n27
    n27 --> n28
    n28 --> n29
    n29 --> n30
    n30 --> n31
    n31 --> n32
    n32 --> n33
    n33 --> n34
    n34 --> n35
    n35 --> n36
    n36 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA Core - 核心引擎模組\n\n這是 AIVA 的核心處理引擎，負責協調...]
    n4[__version__ = '1.0.0']
    n5[from services.aiva_common.enums import ComplianceF...]
    n6[from services.aiva_common.schemas import CVERefere...]
    n7[from services.core.ai_models import AIExperienceCr...]
    n8[from services.core.models import AttackPathEdge, A...]
    n9[__all__ = ['CVEReference', &a...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAI Commander - AIVA 中央 AI 指揮系統\n\n統一指揮所有 A...]
    n4[from __future__ import annotations]
    n5[from datetime import datetime]
    n6[from enum import Enum]
    n7[import logging]
    n8[from pathlib import Path]
    n9[from typing import Any]
    n10[from aiva_core.ai_engine import BioNeuronRAGAgent]
    n11[from aiva_core.learning.experience_manager import ...]
    n12[from aiva_core.learning.model_trainer import Model...]
    n13[from aiva_core.multilang_coordinator import MultiL...]
    n14[from aiva_core.rag import KnowledgeBase, RAGEngine...]
    n15[from aiva_core.training.training_orchestrator impo...]
    n16[logger = logging.getLogger(__...]
    n17[class AITaskType(...)]
    n18[class AIComponent(...)]
    n19[class AICommander(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA 統一 AI 控制器 - 整合所有 AI 組件\n將分散的 AI 組件統一在...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[import logging]
    n7[from typing import Any]
    n8[from .ai_engine import BioNeuronRAGAgent]
    n9[logger = logging.getLogger(__...]
    n10[class UnifiedAIController(...)]
    n11[def demonstrate_unified_control(...)]
    n12{if __name__ == '__main__'}
    n13[asyncio.run(demonstrate_unified_control())]
    n14[]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 -->|Yes| n13
    n12 -->|No| n14
    n13 --> n14
    n14 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAI Engine - AIVA 的 AI 決策引擎\n整合生物啟發式神經網路、RA...]
    n4[from __future__ import annotations]
    n5[from .bio_neuron_core_v2 import AntiHallucinationM...]
    n6[from .knowledge_base import KnowledgeBase]
    n7[from .tools import CodeAnalyzer, CodeReader, CodeW...]
    n8[__all__ = ['BiologicalSpikingL...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAI Engine - AIVA 的 AI 決策引擎\n整合生物啟發式神經網路、RA...]
    n4[from __future__ import annotations]
    n5[from .bio_neuron_core_v2 import AntiHallucinationM...]
    n6[from .knowledge_base import KnowledgeBase]
    n7[from .tools import CodeAnalyzer, CodeReader, CodeW...]
    n8[__all__ = ['BiologicalSpikingL...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nBioNeuron Core V2 - 完整 RAG 與工具整合版本\n提供生物啟發...]
    n4[from __future__ import annotations]
    n5[import logging]
    n6[from typing import TYPE_CHECKING, Any]
    n7[import numpy as np]
    n8{if TYPE_CHECKING}
    n9[pass]
    n10[]
    n11[logger = logging.getLogger(__...]
    n12[class BiologicalSpikingLayer(...)]
    n13[class AntiHallucinationModule(...)]
    n14[class ScalableBioNet(...)]
    n15[class BioNeuronRAGAgent(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 -->|Yes| n9
    n8 -->|No| n10
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nKnowledge Base - RAG 知識庫\n提供程式碼索引、檢索和上下文增強...]
    n4[from __future__ import annotations]
    n5[import ast]
    n6[import logging]
    n7[from pathlib import Path]
    n8[from typing import TYPE_CHECKING, Any]
    n9{if TYPE_CHECKING}
    n10[pass]
    n11[]
    n12[logger = logging.getLogger(__...]
    n13[class KnowledgeBase(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 -->|Yes| n10
    n9 -->|No| n11
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nTools - AI 代理工具系統\n提供程式碼讀取、編輯、執行等操作能力\n&am...]
    n4[from __future__ import annotations]
    n5[from abc import ABC, abstractmethod]
    n6[from pathlib import Path]
    n7[import subprocess]
    n8[from typing import TYPE_CHECKING, Any]
    n9{if TYPE_CHECKING}
    n10[pass]
    n11[]
    n12[class Tool(...)]
    n13[class CodeReader(...)]
    n14[class CodeWriter(...)]
    n15[class CodeAnalyzer(...)]
    n16[class CommandExecutor(...)]
    n17[class ScanTrigger(...)]
    n18[class VulnerabilityDetector(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 -->|Yes| n10
    n9 -->|No| n11
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nBioNeuron Core V2 - 完整 RAG 與工具整合版本\n提供生物啟發...]
    n4[from __future__ import annotations]
    n5[import logging]
    n6[from typing import TYPE_CHECKING, Any]
    n7[import numpy as np]
    n8{if TYPE_CHECKING}
    n9[pass]
    n10[]
    n11[logger = logging.getLogger(__...]
    n12[class BiologicalSpikingLayer(...)]
    n13[class AntiHallucinationModule(...)]
    n14[class ScalableBioNet(...)]
    n15[class BioNeuronRAGAgent(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 -->|Yes| n9
    n8 -->|No| n10
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nKnowledge Base - RAG 知識庫\n提供程式碼索引、檢索和上下文增強...]
    n4[from __future__ import annotations]
    n5[import ast]
    n6[import logging]
    n7[from pathlib import Path]
    n8[from typing import TYPE_CHECKING, Any]
    n9{if TYPE_CHECKING}
    n10[pass]
    n11[]
    n12[logger = logging.getLogger(__...]
    n13[class KnowledgeBase(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 -->|Yes| n10
    n9 -->|No| n11
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nTools - AI 代理工具系統\n提供程式碼讀取、編輯、執行等操作能力\n&am...]
    n4[from __future__ import annotations]
    n5[from abc import ABC, abstractmethod]
    n6[from pathlib import Path]
    n7[import subprocess]
    n8[from typing import TYPE_CHECKING, Any]
    n9{if TYPE_CHECKING}
    n10[pass]
    n11[]
    n12[class Tool(...)]
    n13[class CodeReader(...)]
    n14[class CodeWriter(...)]
    n15[class CodeAnalyzer(...)]
    n16[class CommandExecutor(...)]
    n17[class ScanTrigger(...)]
    n18[class VulnerabilityDetector(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 -->|Yes| n10
    n9 -->|No| n11
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n模型訓練與微調管線\n\n從經驗庫提取樣本並對 AI 決策模型進行微調\n&...]
    n4[from .data_loader import ExperienceDataLoader]
    n5[from .model_updater import ModelUpdater]
    n6[from .trainer import ModelTrainer, TrainingConfig]
    n7[__all__ = ['ModelTrainer', &a...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nExperience Data Loader - 經驗數據加載器\n\n從經驗資料庫...]
    n4[from __future__ import annotations]
    n5[import logging]
    n6[from typing import Any]
    n7[import numpy as np]
    n8[logger = logging.getLogger(__...]
    n9[class ExperienceDataLoader(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nModel Updater - 模型更新器\n\n負責定期從經驗庫提取樣本並更新模型...]
    n4[from __future__ import annotations]
    n5[import logging]
    n6[from pathlib import Path]
    n7[import pickle]
    n8[from typing import Any]
    n9[from .data_loader import ExperienceDataLoader]
    n10[from .trainer import ModelTrainer, TrainingConfig]
    n11[logger = logging.getLogger(__...]
    n12[class ModelUpdater(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nModel Trainer - 模型訓練器\n\n執行模型訓練和微調\n&&...]
    n4[from __future__ import annotations]
    n5[from dataclasses import dataclass]
    n6[import logging]
    n7[from typing import Any]
    n8[import numpy as np]
    n9[logger = logging.getLogger(__...]
    n10[class TrainingConfig(...)]
    n11[class ModelTrainer(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[import os]
    n5[import sqlite3]
    n6[import joblib]
    n7[from sklearn.feature_extraction.text import TfidfV...]
    n8[from sklearn.linear_model import LogisticRegressio...]
    n9[from sklearn.metrics import accuracy_score, classi...]
    n10[from sklearn.model_selection import train_test_spl...]
    n11[def create_database(...)]
    n12[def load_data(...)]
    n13[def train_and_save_model(...)]
    n14{if __name__ == '__main__'}
    n15[create_database()]
    n16[accuracy = train_and_save_model...]
    n17[print(f'Model trained and saved with accu...]
    n18[]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 -->|Yes| n15
    n14 -->|No| n18
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAI Engine 與 UI Panel 數據合約\n\n定義 AI 代理、工具系統...]
    n4[from __future__ import annotations]
    n5[from datetime import datetime]
    n6[from typing import Literal]
    n7[from pydantic import BaseModel, Field, field_valid...]
    n8[class ToolExecutionRequest(...)]
    n9[class ToolExecutionResult(...)]
    n10[class AIAgentQuery(...)]
    n11[class AIAgentResponse(...)]
    n12[class RAGChunk(...)]
    n13[class KnowledgeBaseStats(...)]
    n14[class ScanTaskRequest(...)]
    n15[class ScanTaskResponse(...)]
    n16[class VulnerabilityDetectionRequest(...)]
    n17[class VulnerabilityDetectionResponse(...)]
    n18[class CodeOperationRequest(...)]
    n19[class CodeOperationResponse(...)]
    n20[class DashboardStats(...)]
    n21[class UIServerConfig(...)]
    n22[class CodeReadResult(...)]
    n23[class CodeWriteResult(...)]
    n24[class CodeAnalysisResult(...)]
    n25[class CommandExecutionResult(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n22
    n22 --> n23
    n23 --> n24
    n24 --> n25
    n25 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAnalysis Module - 分析和評估模組\n\n提供 AST/Trace ...]
    n4[from .plan_comparator import PlanComparator]
    n5[__all__ = ['PlanComparator']]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAST 與 Trace 對比分析模組\n\n比較預期的攻擊流程圖 (AST&...]
    n4[from __future__ import annotations]
    n5[from dataclasses import asdict, dataclass, field]
    n6[import logging]
    n7[from typing import Any]
    n8[from ..execution_tracer.trace_recorder import Exec...]
    n9[from ..planner.ast_parser import AttackFlowGraph, ...]
    n10[logger = logging.getLogger(__...]
    n11[class ComparisonMetrics(...)]
    n12[class StepComparison(...)]
    n13[class ASTTraceComparator(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from typing import Any]
    n5[from services.aiva_common.utils import get_logger]
    n6[logger = get_logger(__name__)]
    n7[class StrategyAdjuster(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from typing import Any]
    n5[from services.aiva_common.schemas import Asset, Sc...]
    n6[from services.core.aiva_core.schemas import AssetA...]
    n7[class InitialAttackSurface(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nPlan Comparator - 攻擊計畫對比分析器\n\n負責對比 AST 預期...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[import logging]
    n7[from typing import Any]
    n8[from services.aiva_common.schemas import AttackPla...]
    n9[logger = logging.getLogger(__...]
    n10[class StepMatch(...)]
    n11[class PlanComparator(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nRisk Assessment Engine - 風險評估引擎\n\n整合多維度風險...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[from typing import TYPE_CHECKING]
    n7[from services.aiva_common.enums import Severity, T...]
    n8[from services.aiva_common.schemas import FindingPa...]
    n9[from services.aiva_common.utils import get_logger]
    n10{if TYPE_CHECKING}
    n11[from services.integration.aiva_integration.threat_...]
    n12[]
    n13[logger = get_logger(__name__)]
    n14[class RiskAssessmentEngine(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 -->|Yes| n11
    n10 -->|No| n12
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n基於規則的測試策略生成器\n\n從攻擊面分析結果生成測試策略，包括：\n- XSS ...]
    n4[import logging]
    n5[from services.aiva_common.schemas import ScanCompl...]
    n6[from services.core.aiva_core.schemas import Attack...]
    n7[logger = logging.getLogger(__...]
    n8[class RuleBasedStrategyGenerator(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[import asyncio]
    n5[from collections import Counter]
    n6[from typing import Any]
    n7[from fastapi import FastAPI]
    n8[from tenacity import RetryError, retry, stop_after...]
    n9[from services.aiva_common.config import get_settin...]
    n10[from services.aiva_common.enums import Topic]
    n11[from services.aiva_common.mq import get_broker]
    n12[from services.aiva_common.schemas import AivaMessa...]
    n13[from services.aiva_common.utils import get_logger]
    n14[from services.core.aiva_core.analysis.dynamic_stra...]
    n15[from services.core.aiva_core.analysis.initial_surf...]
    n16[from services.core.aiva_core.execution.execution_s...]
    n17[from services.core.aiva_core.execution.task_genera...]
    n18[from services.core.aiva_core.execution.task_queue_...]
    n19[from services.core.aiva_core.ingestion.scan_module...]
    n20[from services.core.aiva_core.processing import Sca...]
    n21[from services.core.aiva_core.state.session_state_m...]
    n22[app = FastAPI(title='AIVA ...]
    n23[logger = get_logger(__name__)]
    n24[def _count_tasks_by_type(...)]
    n25[scan_interface = ScanModuleInterface(...]
    n26[surface_analyzer = InitialAttackSurface...]
    n27[strategy_adjuster = StrategyAdjuster()]
    n28[task_generator = TaskGenerator()]
    n29[task_queue_manager = TaskQueueManager()]
    n30[execution_monitor = ExecutionStatusMonit...]
    n31[session_state_manager = SessionStateManager(...]
    n32[scan_result_processor = ScanResultProcessor(...]
    n33[def startup(...)]
    n34[def health_check(...)]
    n35[def get_scan_status(...)]
    n36[def _process_single_scan_with_retry(...)]
    n37[def process_scan_results(...)]
    n38[def process_function_results(...)]
    n39[def monitor_execution_status(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n22
    n22 --> n23
    n23 --> n24
    n24 --> n25
    n25 --> n26
    n26 --> n27
    n27 --> n28
    n28 --> n29
    n29 --> n30
    n30 --> n31
    n31 --> n32
    n32 --> n33
    n33 --> n34
    n34 --> n35
    n35 --> n36
    n36 --> n37
    n37 --> n38
    n38 --> n39
    n39 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAuthZ Module - 授權與權限分析模組\n\n提供權限矩陣分析、角色映射、...]
    n4[from .authz_mapper import AuthZMapper]
    n5[from .matrix_visualizer import MatrixVisualizer]
    n6[from .permission_matrix import PermissionMatrix]
    n7[__all__ = ['PermissionMatrix'...]
    n8[__version__ = '1.0.0']
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAuthZ Mapper - 權限映射器\n\n測試多角色權限、映射用戶到角色、分析...]
    n4[from datetime import datetime]
    n5[from typing import Any]
    n6[import structlog]
    n7[from .permission_matrix import AccessDecision, Per...]
    n8[logger = structlog.get_logger...]
    n9[class AuthZMapper(...)]
    n10[def main(...)]
    n11{if __name__ == '__main__'}
    n12[main()]
    n13[]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 -->|Yes| n12
    n11 -->|No| n13
    n12 --> n13
    n13 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nMatrix Visualizer - 權限矩陣視覺化\n\n生成權限矩陣的 HTM...]
    n4[from datetime import datetime]
    n5[from pathlib import Path]
    n6[from jinja2 import Template]
    n7[import plotly.graph_objects as go]
    n8[from plotly.subplots import make_subplots]
    n9[import structlog]
    n10[from .permission_matrix import AccessDecision, Per...]
    n11[logger = structlog.get_logger...]
    n12[class MatrixVisualizer(...)]
    n13[def main(...)]
    n14{if __name__ == '__main__'}
    n15[main()]
    n16[]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 -->|Yes| n15
    n14 -->|No| n16
    n15 --> n16
    n16 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nPermission Matrix - 權限矩陣數據結構與分析\n\n提供權限矩陣的...]
    n4[from datetime import datetime]
    n5[from typing import Any]
    n6[import numpy as np]
    n7[import pandas as pd]
    n8[import structlog]
    n9[from services.aiva_common.enums import AccessDecis...]
    n10[logger = structlog.get_logger...]
    n11[class PermissionMatrix(...)]
    n12[def main(...)]
    n13{if __name__ == '__main__'}
    n14[main()]
    n15[]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 -->|Yes| n14
    n13 -->|No| n15
    n14 --> n15
    n15 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nBioNeuron Master Controller - BioNeuronRAG...]
    n4[from __future__ import annotations]
    n5[from collections.abc import Callable]
    n6[from datetime import datetime]
    n7[from enum import Enum]
    n8[import logging]
    n9[from typing import Any]
    n10[from aiva_core.ai_engine import BioNeuronRAGAgent]
    n11[from aiva_core.rag import RAGEngine]
    n12[logger = logging.getLogger(__...]
    n13[class OperationMode(...)]
    n14[class ConversationContext(...)]
    n15[class BioNeuronMasterController(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nBizLogic Module - 業務邏輯漏洞測試模組\n\n測試應用程式的業務邏...]
    n4[from __future__ import annotations]
    n5[__version__ = '1.0.0']
    n6[__all__ = ['PriceManipulationT...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nBizLogic Finding 創建輔助函數\n']
    n4[from __future__ import annotations]
    n5[from typing import Any]
    n6[from services.aiva_common.enums import Confidence,...]
    n7[from services.aiva_common.schemas import FindingEv...]
    n8[from services.aiva_common.utils import new_id]
    n9[def create_bizlogic_finding(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nBizLogic Worker - 業務邏輯漏洞測試 Worker\n\n監聽業務邏...]
    n4[from __future__ import annotations]
    n5[import json]
    n6[from services.aiva_common.enums import ModuleName,...]
    n7[from services.aiva_common.mq import get_broker]
    n8[from services.aiva_common.schemas import AivaMessa...]
    n9[from services.aiva_common.utils import get_logger,...]
    n10[from .price_manipulation_tester import PriceManipu...]
    n11[from .race_condition_tester import RaceConditionTe...]
    n12[from .workflow_bypass_tester import WorkflowBypass...]
    n13[logger = get_logger(__name__)]
    n14[def run(...)]
    n15[def _perform_test(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA 核心業務模式定義\n\n包含風險評估、任務管理、策略生成、系統協調等核心業...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any]
    n7[from aiva_common.enums import ModuleName, Severity...]
    n8[from aiva_common.standards import CVSSv3Metrics]
    n9[from pydantic import BaseModel, Field, field_valid...]
    n10[class RiskFactor(...)]
    n11[class RiskAssessment(...)]
    n12[class AttackPathNode(...)]
    n13[class AttackPath(...)]
    n14[class TaskDependency(...)]
    n15[class TaskExecution(...)]
    n16[class TaskQueue(...)]
    n17[class TestStrategy(...)]
    n18[class ModuleStatus(...)]
    n19[class SystemOrchestration(...)]
    n20[class VulnerabilityCorrelation(...)]
    n21[__all__ = ['RiskFactor', &amp...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nExecution Module - 攻擊計畫執行模組\n\n提供攻擊計畫的執行、追...]
    n4[from .plan_executor import PlanExecutor]
    n5[from .trace_logger import TraceLogger]
    n6[__all__ = ['PlanExecutor', &a...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[import asyncio]
    n5[from datetime import UTC, datetime, timedelta]
    n6[from typing import Any]
    n7[from services.aiva_common.utils import get_logger]
    n8[logger = get_logger(__name__)]
    n9[class ExecutionStatusMonitor(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nPlan Executor - 攻擊計畫執行器\n\n負責執行攻擊計畫，管理會話狀態...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[from datetime import UTC, datetime]
    n7[import logging]
    n8[from typing import Any]
    n9[from uuid import uuid4]
    n10[from services.aiva_common.schemas import AttackPla...]
    n11[from .trace_logger import TraceLogger]
    n12[logger = logging.getLogger(__...]
    n13[class PlanExecutor(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from collections.abc import Iterable]
    n5[from services.aiva_common.enums import Topic]
    n6[from services.aiva_common.schemas import FunctionT...]
    n7[class TaskGenerator(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from collections import defaultdict]
    n5[from datetime import UTC, datetime]
    n6[from queue import PriorityQueue]
    n7[from typing import Any]
    n8[from services.aiva_common.enums import Topic]
    n9[from services.aiva_common.schemas import FunctionT...]
    n10[from services.aiva_common.utils import get_logger]
    n11[logger = get_logger(__name__)]
    n12[class TaskQueueManager(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nTrace Logger - 執行追蹤記錄器\n\n負責記錄攻擊計畫執行過程中的所有...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[import logging]
    n7[from typing import Any]
    n8[from uuid import uuid4]
    n9[from services.aiva_common.schemas import SessionSt...]
    n10[logger = logging.getLogger(__...]
    n11[class TraceLogger(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n任務執行與 Trace 紀錄模組\n\n負責監控任務執行過程並詳細記錄每個步驟的 t...]
    n4[from .execution_monitor import ExecutionContext, E...]
    n5[from .task_executor import ExecutionResult, TaskEx...]
    n6[from .trace_recorder import TraceEntry, TraceRecor...]
    n7[__all__ = ['TraceRecorder', &...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nExecution Monitor - 執行監控器\n\n監控任務執行狀態並協調 T...]
    n4[from __future__ import annotations]
    n5[from dataclasses import dataclass, field]
    n6[from datetime import datetime]
    n7[import logging]
    n8[from typing import TYPE_CHECKING, Any]
    n9{if TYPE_CHECKING}
    n10[from ..planner.orchestrator import ExecutionPlan]
    n11[from ..planner.task_converter import ExecutableTas...]
    n12[from ..planner.tool_selector import ToolDecision]
    n13[]
    n14[from .trace_recorder import ExecutionTrace, TraceR...]
    n15[logger = logging.getLogger(__...]
    n16[class ExecutionContext(...)]
    n17[class ExecutionMonitor(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 -->|Yes| n10
    n9 -->|No| n13
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nTask Executor - 任務執行器\n\n實際執行任務並與各種服務整合\n&...]
    n4[from __future__ import annotations]
    n5[from dataclasses import dataclass]
    n6[import logging]
    n7[from typing import TYPE_CHECKING, Any]
    n8{if TYPE_CHECKING}
    n9[from ..planner.task_converter import ExecutableTas...]
    n10[from ..planner.tool_selector import ToolDecision]
    n11[]
    n12[from .execution_monitor import ExecutionContext, E...]
    n13[logger = logging.getLogger(__...]
    n14[class ExecutionResult(...)]
    n15[class TaskExecutor(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 -->|Yes| n9
    n8 -->|No| n11
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nTrace Recorder - 軌跡記錄器\n\n記錄任務執行過程中的所有詳細信息...]
    n4[from __future__ import annotations]
    n5[from dataclasses import asdict, dataclass, field]
    n6[from datetime import datetime]
    n7[from enum import Enum]
    n8[import json]
    n9[import logging]
    n10[from typing import Any]
    n11[from uuid import uuid4]
    n12[logger = logging.getLogger(__...]
    n13[class TraceType(...)]
    n14[class TraceEntry(...)]
    n15[class ExecutionTrace(...)]
    n16[class TraceRecorder(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n1 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nLearning Module - 機器學習和經驗管理模組\n\n提供經驗樣本管理、...]
    n4[from .experience_manager import ExperienceManager]
    n5[from .model_trainer import ModelTrainer]
    n6[__all__ = ['ExperienceManager&#39...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nExperience Manager - 經驗樣本管理器\n\n負責收集、存儲和管理...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[import logging]
    n7[from typing import Any]
    n8[from uuid import uuid4]
    n9[from services.aiva_common.schemas import AttackPla...]
    n10[logger = logging.getLogger(__...]
    n11[class ExperienceManager(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nModel Trainer - 強化學習模型訓練器\n\n負責模型的訓練、評估、微調...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[import logging]
    n7[from pathlib import Path]
    n8[from typing import Any]
    n9[from uuid import uuid4]
    n10[from services.aiva_common.schemas import Experienc...]
    n11[import numpy as np]
    n12[logger = logging.getLogger(__...]
    n13[class ModelTrainer(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA 多語言 AI 協調架構\n統一協調 Python/Go/Rust/Type...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[from dataclasses import dataclass]
    n7[import logging]
    n8[from typing import Any]
    n9[logger = logging.getLogger(__...]
    n10[class LanguageModuleInfo(...)]
    n11[class AICoordinationTask(...)]
    n12[class MultiLanguageAICoordinator(...)]
    n13[def demonstrate_multilang_ai_coordination(...)]
    n14{if __name__ == '__main__'}
    n15[asyncio.run(demonstrate_multilang_ai_coordination&#40...]
    n16[]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 -->|Yes| n15
    n14 -->|No| n16
    n15 --> n16
    n16 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA 自然語言生成增強系統\n基於規則和模板的高品質中文回應生成，無需外部 LL...]
    n4[from __future__ import annotations]
    n5[import random]
    n6[import re]
    n7[from typing import Any]
    n8[class AIVANaturalLanguageGenerator(...)]
    n9[def test_nlg_system(...)]
    n10{if __name__ == '__main__'}
    n11[test_nlg_system()]
    n12[]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 -->|Yes| n11
    n10 -->|No| n12
    n11 --> n12
    n12 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n1 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n攻擊計畫執行器 (Planner/Orchestrator)\n\n...]
    n4[from .ast_parser import ASTParser, AttackFlowGraph...]
    n5[from .orchestrator import AttackOrchestrator]
    n6[from .task_converter import ExecutableTask, TaskCo...]
    n7[from .tool_selector import ToolDecision, ToolSelec...]
    n8[__all__ = ['ASTParser', &...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAST Parser - 攻擊流程圖解析器\n\n負責解析 AI 引擎生成的攻擊流程...]
    n4[from __future__ import annotations]
    n5[from dataclasses import dataclass, field]
    n6[from enum import Enum]
    n7[import logging]
    n8[from typing import Any]
    n9[logger = logging.getLogger(__...]
    n10[class NodeType(...)]
    n11[class AttackFlowNode(...)]
    n12[class AttackFlowEdge(...)]
    n13[class AttackFlowGraph(...)]
    n14[class ASTParser(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAttack Orchestrator - 攻擊編排器\n\n統籌整個攻擊計畫的執行...]
    n4[from __future__ import annotations]
    n5[from dataclasses import dataclass, field]
    n6[import logging]
    n7[from typing import Any]
    n8[from uuid import uuid4]
    n9[from .ast_parser import ASTParser, AttackFlowGraph]
    n10[from .task_converter import ExecutableTask, TaskCo...]
    n11[from .tool_selector import ToolDecision, ToolSelec...]
    n12[logger = logging.getLogger(__...]
    n13[class ExecutionPlan(...)]
    n14[class AttackOrchestrator(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nTask Converter - 任務轉換器\n\n將 AST 節點轉換為可執行的任...]
    n4[from __future__ import annotations]
    n5[from dataclasses import dataclass, field]
    n6[from enum import Enum]
    n7[import logging]
    n8[from typing import Any]
    n9[from uuid import uuid4]
    n10[from .ast_parser import AttackFlowGraph, AttackFlo...]
    n11[logger = logging.getLogger(__...]
    n12[class TaskStatus(...)]
    n13[class TaskPriority(...)]
    n14[class ExecutableTask(...)]
    n15[class TaskSequence(...)]
    n16[class TaskConverter(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nTool Selector - 工具選擇器\n\n根據任務類型和參數決定使用哪個功能...]
    n4[from __future__ import annotations]
    n5[from dataclasses import dataclass]
    n6[from enum import Enum]
    n7[import logging]
    n8[from typing import Any]
    n9[from .task_converter import ExecutableTask]
    n10[logger = logging.getLogger(__...]
    n11[class ServiceType(...)]
    n12[class ToolDecision(...)]
    n13[class ToolSelector(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['Processing module - 處理器模組']
    n4[from .scan_result_processor import ScanResultProce...]
    n5[__all__ = ['ScanResultProcesso...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nRAG Module - 檢索增強生成模組\n\n負責向量數據庫管理、知識檢索和增強...]
    n4[from .knowledge_base import KnowledgeBase]
    n5[from .rag_engine import RAGEngine]
    n6[from .vector_store import VectorStore]
    n7[__all__ = ['KnowledgeBase', &...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nKnowledge Base - 知識庫管理\n\n管理漏洞知識、攻擊技術、最佳實踐...]
    n4[from __future__ import annotations]
    n5[from dataclasses import dataclass, field]
    n6[from datetime import datetime]
    n7[from enum import Enum]
    n8[import json]
    n9[import logging]
    n10[from pathlib import Path]
    n11[from typing import Any]
    n12[from services.aiva_common.schemas import AttackPla...]
    n13[from .vector_store import VectorStore]
    n14[logger = logging.getLogger(__...]
    n15[class KnowledgeType(...)]
    n16[class KnowledgeEntry(...)]
    n17[class KnowledgeBase(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nRAG Engine - 檢索增強生成引擎\n\n將知識庫檢索與 AI 決策結合，增...]
    n4[from __future__ import annotations]
    n5[import logging]
    n6[from typing import Any]
    n7[from services.aiva_common.schemas import AttackPla...]
    n8[from .knowledge_base import KnowledgeBase, Knowled...]
    n9[logger = logging.getLogger(__...]
    n10[class RAGEngine(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nVector Store - 向量數據庫\n\n負責向量化和存儲攻擊模式、經驗樣本、...]
    n4[from __future__ import annotations]
    n5[import json]
    n6[import logging]
    n7[from pathlib import Path]
    n8[from typing import Any]
    n9[import numpy as np]
    n10[logger = logging.getLogger(__...]
    n11[class VectorStore(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nCore 模組專用數據合約\n\n定義核心引擎的內部數據結構，包括：\n- 攻擊面分...]
    n4[from typing import Literal]
    n5[from pydantic import BaseModel, Field, field_valid...]
    n6[class AssetAnalysis(...)]
    n7[class VulnerabilityCandidate(...)]
    n8[class XssCandidate(...)]
    n9[class SqliCandidate(...)]
    n10[class SsrfCandidate(...)]
    n11[class IdorCandidate(...)]
    n12[class AttackSurfaceAnalysis(...)]
    n13[class TestTask(...)]
    n14[class TestStrategy(...)]
    n15[class StrategyAdjustment(...)]
    n16[class LearningFeedback(...)]
    n17[class StrategyGenerationConfig(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n1 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from datetime import UTC, datetime]
    n5[from typing import Any]
    n6[from services.aiva_common.schemas import ScanCompl...]
    n7[from services.aiva_common.utils import get_logger]
    n8[logger = get_logger(__name__)]
    n9[class SessionStateManager(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA 數據存儲模組\n\n提供統一的數據存儲接口，支持多種後端：\n- SQLi...]
    n4[from .backends import HybridBackend, JSONLBackend,...]
    n5[from .models import ExperienceSampleModel, Knowled...]
    n6[from .storage_manager import StorageManager]
    n7[__all__ = ['StorageManager', ...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n數據存儲後端實現\n\n支持多種存儲後端：\n- SQLite: 輕量級，適合開發和...]
    n4[from abc import ABC, abstractmethod]
    n5[from datetime import datetime]
    n6[import json]
    n7[from pathlib import Path]
    n8[from typing import Any]
    n9[from sqlalchemy import create_engine, desc, func]
    n10[from sqlalchemy.orm import sessionmaker]
    n11[from .models import Base, ExperienceSampleModel, K...]
    n12[class StorageBackend(...)]
    n13[class SQLiteBackend(...)]
    n14[class PostgreSQLBackend(...)]
    n15[class JSONLBackend(...)]
    n16[class HybridBackend(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA 數據存儲配置\n\n配置存儲後端、路徑和其他選項\n']
    n4[import os]
    n5[from pathlib import Path]
    n6[from typing import Any]
    n7[DATA_ROOT = Path(os.getenv('AIVA...]
    n8[DATABASE_TYPE = os.getenv('AIVA_DB_T...]
    n9[DATABASE_URL = os.getenv('AIVA_DB_U...]
    n10[POSTGRES_CONFIG = {'host': o...]
    n11[EXPERIENCE_STORAGE = os.getenv('AIVA_EXPE...]
    n12[DATA_RETENTION = {'high_quality_sampl...]
    n13[AUTO_BACKUP = {'enabled': os...]
    n14[PATHS: dict[str, Any] = {'traini...]
    n15[QUALITY_THRESHOLDS = {'high'...]
    n16[BATCH_CONFIG = {'save_batch_size&&#3...]
    n17[def get_storage_config(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nSQLAlchemy ORM 模型定義\n\n所有訓練數據的數據庫模型\n&...]
    n4[from datetime import datetime]
    n5[from sqlalchemy import JSON, Boolean, Column, Date...]
    n6[from sqlalchemy.orm import declarative_base, relat...]
    n7[Base = declarative_base()]
    n8[class ExperienceSampleModel(...)]
    n9[class TraceRecordModel(...)]
    n10[class TrainingSessionModel(...)]
    n11[class ModelCheckpointModel(...)]
    n12[class KnowledgeEntryModel(...)]
    n13[class ScenarioModel(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n存儲管理器\n\n統一的存儲接口，管理所有數據持久化\n']
    n4[import logging]
    n5[from pathlib import Path]
    n6[from typing import Any]
    n7[from .backends import HybridBackend, JSONLBackend,...]
    n8[logger = logging.getLogger(__...]
    n9[class StorageManager(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nTraining Module - 訓練和場景管理模組\n\n提供 OWASP 靶場...]
    n4[from services.aiva_common.schemas import Scenario,...]
    n5[from .scenario_manager import ScenarioManager]
    n6[from .training_orchestrator import TrainingOrchest...]
    n7[__all__ = ['Scenario', &&...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nStandard Scenario Manager - OWASP 靶場場景管理器\...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[import json]
    n7[import logging]
    n8[from pathlib import Path]
    n9[from typing import Any]
    n10[from uuid import uuid4]
    n11[from services.aiva_common.enums import Vulnerabili...]
    n12[from services.aiva_common.schemas import AttackPla...]
    n13[logger = logging.getLogger(__...]
    n14[class ScenarioManager(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nTraining Orchestrator - 訓練編排器\n\n整合 RAG、場景...]
    n4[from __future__ import annotations]
    n5[from datetime import datetime]
    n6[import logging]
    n7[from pathlib import Path]
    n8[from typing import Any]
    n9[from aiva_core.execution.plan_executor import Plan...]
    n10[from aiva_core.learning.experience_manager import ...]
    n11[from aiva_core.learning.model_trainer import Model...]
    n12[from aiva_core.rag import RAGEngine]
    n13[from aiva_core.training.scenario_manager import Sc...]
    n14[from services.aiva_common.schemas import AttackPla...]
    n15[logger = logging.getLogger(__...]
    n16[class TrainingOrchestrator(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nUI Panel - AIVA 核心 Web 控制面板\n提供圖形化介面來管理和控制...]
    n4[from .auto_server import start_auto_server]
    n5[from .dashboard import Dashboard]
    n6[from .server import start_ui_server]
    n7[__all__ = ['Dashboard', &...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAuto Server - AIVA UI 自動端口伺服器\n自動選擇可用端口啟動 ...]
    n4[from __future__ import annotations]
    n5[import logging]
    n6[from pathlib import Path]
    n7[import socket]
    n8[import sys]
    n9[project_root = Path(__file__).paren...]
    n10{if str(project_root) not in sy...}
    n11[sys.path.insert(0, str(project_root))]
    n12[]
    n13[logger = logging.getLogger(__...]
    n14[def find_free_port(...)]
    n15[def start_auto_server(...)]
    n16[def main(...)]
    n17{if __name__ == '__main__'}
    n18[main()]
    n19[]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 -->|Yes| n11
    n10 -->|No| n12
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 -->|Yes| n18
    n17 -->|No| n19
    n18 --> n19
    n19 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nDashboard - AIVA 主控制面板\n提供 Web UI 來管理掃描、AI...]
    n4[from __future__ import annotations]
    n5[import logging]
    n6[from typing import TYPE_CHECKING, Any]
    n7{if TYPE_CHECKING}
    n8[pass]
    n9[]
    n10[logger = logging.getLogger(__...]
    n11[class Dashboard(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 -->|Yes| n8
    n7 -->|No| n9
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nImproved UI for AIVA Control Panel.\n\nThi...]
    n4[from __future__ import annotations]
    n5[import sys]
    n6[from typing import Any]
    n7[from fastapi import FastAPI]
    n8[from fastapi.responses import HTMLResponse]
    n9[PROJECT_ROOT = '/home/oai/share/AIV...]
    n10{if PROJECT_ROOT not in sys.path}
    n11[sys.path.append(PROJECT_ROOT)]
    n12[]
    n13[try]
    n14[from services.core.aiva_core.ui_panel.dashboard im...]
    n15[]
    n16[except Exception]
    n17[raise ImportError('Unable to import Dashb...]
    n18[def _build_index_html(...)]
    n19[def create_app(...)]
    n20[app = create_app()]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 -->|Yes| n11
    n10 -->|No| n12
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n13 --> n16
    n14 --> n15
    n15 --> n18
    n16 --> n17
    n17 --> n15
    n18 --> n19
    n19 --> n20
    n20 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nServer - AIVA UI 面板 Web 伺服器\n使用 FastAPI 提供...]
    n4[from __future__ import annotations]
    n5[import logging]
    n6[import socket]
    n7[from typing import TYPE_CHECKING, Any]
    n8{if TYPE_CHECKING}
    n9[pass]
    n10[]
    n11[logger = logging.getLogger(__...]
    n12[def find_free_port(...)]
    n13[def start_ui_server(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 -->|Yes| n9
    n8 -->|No| n10
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAIVA Core Models - 核心業務模組\n\n此文件包含AIVA系統核心...]
    n4[from __future__ import annotations]
    n5[from datetime import UTC, datetime]
    n6[from typing import Any]
    n7[from pydantic import BaseModel, Field, HttpUrl, fi...]
    n8[from ..aiva_common.enums import AttackPathEdgeType...]
    n9[from ..aiva_common.schemas import CVSSv3Metrics, C...]
    n10[class Target(...)]
    n11[class FindingEvidence(...)]
    n12[class FindingImpact(...)]
    n13[class FindingRecommendation(...)]
    n14[class FindingPayload(...)]
    n15[class EnhancedVulnerability(...)]
    n16[class EnhancedFindingPayload(...)]
    n17[class FeedbackEventPayload(...)]
    n18[class RiskFactor(...)]
    n19[class RiskAssessmentContext(...)]
    n20[class RiskAssessmentResult(...)]
    n21[class EnhancedRiskAssessment(...)]
    n22[class RiskTrendAnalysis(...)]
    n23[class AttackPathNode(...)]
    n24[class AttackPathEdge(...)]
    n25[class AttackPathPayload(...)]
    n26[class AttackPathRecommendation(...)]
    n27[class EnhancedAttackPathNode(...)]
    n28[class EnhancedAttackPath(...)]
    n29[class VulnerabilityCorrelation(...)]
    n30[class EnhancedVulnerabilityCorrelation(...)]
    n31[class CodeLevelRootCause(...)]
    n32[class SASTDASTCorrelation(...)]
    n33[class TaskUpdatePayload(...)]
    n34[class TaskDependency(...)]
    n35[class EnhancedTaskExecution(...)]
    n36[class TaskQueue(...)]
    n37[class TestStrategy(...)]
    n38[class ModuleStatus(...)]
    n39[class EnhancedModuleStatus(...)]
    n40[class HeartbeatPayload(...)]
    n41[class ConfigUpdatePayload(...)]
    n42[class SystemOrchestration(...)]
    n43[class RemediationGeneratePayload(...)]
    n44[class RemediationResultPayload(...)]
    n45[__all__ = ['Target', &&#3...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n22
    n22 --> n23
    n23 --> n24
    n24 --> n25
    n25 --> n26
    n26 --> n27
    n27 --> n28
    n28 --> n29
    n29 --> n30
    n30 --> n31
    n31 --> n32
    n32 --> n33
    n33 --> n34
    n34 --> n35
    n35 --> n36
    n36 --> n37
    n37 --> n38
    n38 --> n39
    n39 --> n40
    n40 --> n41
    n41 --> n42
    n42 --> n43
    n43 --> n44
    n44 --> n45
    n45 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nMessaging Module - 消息處理模組\n\n負責與各功能模組的消息交互...]
    n4[from .message_broker import MessageBroker]
    n5[from .result_collector import ResultCollector]
    n6[from .task_dispatcher import TaskDispatcher]
    n7[__all__ = ['MessageBroker', &...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nMessage Broker - 消息代理\n\n統一管理 RabbitMQ 連接和...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[from collections.abc import Callable]
    n7[from contextlib import suppress]
    n8[import json]
    n9[import logging]
    n10[from typing import Any]
    n11[import aio_pika]
    n12[from aio_pika.abc import AbstractChannel, Abstract...]
    n13[from services.aiva_common.config import get_settin...]
    n14[from services.aiva_common.enums import ModuleName]
    n15[from services.aiva_common.schemas import AivaMessa...]
    n16[logger = logging.getLogger(__...]
    n17[class MessageBroker(...)]
    n18[class RPCClient(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nResult Collector - 結果收集器\n\n接收並處理各功能模組傳回的執...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[from collections.abc import Callable]
    n7[from datetime import UTC, datetime]
    n8[import json]
    n9[import logging]
    n10[from typing import Any]
    n11[from aio_pika.abc import AbstractIncomingMessage]
    n12[from services.aiva_common.schemas import FindingPa...]
    n13[from .message_broker import MessageBroker]
    n14[logger = logging.getLogger(__...]
    n15[class ResultCollector(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nTask Dispatcher - 任務派發器\n\n負責將攻擊計畫轉換為任務並派發...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[from collections.abc import Callable]
    n7[from datetime import UTC, datetime]
    n8[import logging]
    n9[from typing import Any]
    n10[from uuid import uuid4]
    n11[from services.aiva_common.schemas import AivaMessa...]
    n12[from .message_broker import MessageBroker]
    n13[logger = logging.getLogger(__...]
    n14[class TaskDispatcher(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n1 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n1 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from services.aiva_common.schemas import Authentic...]
    n5[class AuthenticationManager(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from dataclasses import dataclass, field]
    n5[from typing import Any]
    n6[from services.aiva_common.utils import get_logger]
    n7[logger = get_logger(__name__)]
    n8[class CrawlingConfig(...)]
    n9[class DynamicScanConfig(...)]
    n10[class FingerprintConfig(...)]
    n11[class SecurityConfig(...)]
    n12[class PerformanceConfig(...)]
    n13[class ReportingConfig(...)]
    n14[class ScanModuleConfig(...)]
    n15[class ConfigControlCenter(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n1 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from typing import Any]
    n5[from urllib.parse import urlparse]
    n6[import httpx]
    n7[from services.aiva_common.utils import get_logger]
    n8[from services.aiva_common.utils.network import Rat...]
    n9[from ..authentication_manager import Authenticatio...]
    n10[from ..header_configuration import HeaderConfigura...]
    n11[logger = get_logger(__name__)]
    n12[class HiHttpClient(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from urllib.parse import urljoin]
    n5[from bs4 import BeautifulSoup]
    n6[import httpx]
    n7[from services.aiva_common.schemas import Asset]
    n8[from services.aiva_common.utils.ids import new_id]
    n9[class StaticContentParser(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from collections import deque]
    n5[from urllib.parse import urljoin, urlparse]
    n6[from services.aiva_common.utils import get_logger]
    n7[logger = get_logger(__name__)]
    n8[class UrlQueueManager(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nDynamic Engine Module\n\n用於處理動態內容的模組，包括：\n...]
    n4[from __future__ import annotations]
    n5[from .ajax_api_handler import AjaxApiHandler]
    n6[from .dynamic_content_extractor import ContentType...]
    n7[from .headless_browser_pool import BrowserInstance...]
    n8[from .js_interaction_simulator import InteractionR...]
    n9[__all__ = ['AjaxApiHandler', ...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nAJAX 和 API 端點處理器\n擴展動態引擎以識別和處理 AJAX 請求和 AP...]
    n4[from __future__ import annotations]
    n5[import re]
    n6[from typing import Any]
    n7[from urllib.parse import urljoin, urlparse]
    n8[from services.aiva_common.schemas import Asset]
    n9[from services.aiva_common.utils import get_logger,...]
    n10[logger = get_logger(__name__)]
    n11[class AjaxApiHandler(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[import asyncio]
    n5[from dataclasses import dataclass, field]
    n6[from datetime import datetime]
    n7[from enum import Enum]
    n8[import re]
    n9[from typing import Any]
    n10[from urllib.parse import urljoin]
    n11[from bs4 import BeautifulSoup]
    n12[from services.aiva_common.schemas import Asset]
    n13[from services.aiva_common.utils import get_logger]
    n14[from services.aiva_common.utils.ids import new_id]
    n15[logger = get_logger(__name__)]
    n16[class ContentType(...)]
    n17[class ExtractionStrategy(...)]
    n18[class DynamicContent(...)]
    n19[class NetworkRequest(...)]
    n20[class ExtractionConfig(...)]
    n21[class DynamicContentExtractor(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n20
    n20 --> n21
    n21 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nHeadlessBrowserPool 使用範例\n\n展示如何使用 Headles...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[from .headless_browser_pool import BrowserType, He...]
    n7[def example_basic_usage(...)]
    n8[def example_custom_config(...)]
    n9[def example_execute_callback(...)]
    n10[def example_multiple_pages(...)]
    n11[def example_browser_info(...)]
    n12[def example_cleanup(...)]
    n13[def example_error_handling(...)]
    n14[def main(...)]
    n15{if __name__ == '__main__'}
    n16[asyncio.run(main())]
    n17[]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 -->|Yes| n16
    n15 -->|No| n17
    n16 --> n17
    n17 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nDynamicContentExtractor 使用範例\n\n展示如何使用 Dyn...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[from .dynamic_content_extractor import ContentType...]
    n7[from .headless_browser_pool import HeadlessBrowser...]
    n8[def example_basic_usage(...)]
    n9[def example_with_browser_pool(...)]
    n10[def example_custom_config(...)]
    n11[def example_extract_by_type(...)]
    n12[def example_network_requests(...)]
    n13[def example_convert_to_assets(...)]
    n14[def example_after_interaction(...)]
    n15[def example_clear_and_reuse(...)]
    n16[def main(...)]
    n17{if __name__ == '__main__'}
    n18[asyncio.run(main())]
    n19[]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 -->|Yes| n18
    n17 -->|No| n19
    n18 --> n19
    n19 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nJsInteractionSimulator 使用範例\n\n展示如何使用 JsIn...]
    n4[from __future__ import annotations]
    n5[import asyncio]
    n6[import logging]
    n7[from .js_interaction_simulator import InteractionT...]
    n8[logger = logging.getLogger(__...]
    n9[def example_basic_usage(...)]
    n10[def example_advanced_usage(...)]
    n11[def example_with_playwright(...)]
    n12[def example_error_handling(...)]
    n13[def main(...)]
    n14{if __name__ == '__main__'}
    n15[asyncio.run(main())]
    n16[]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 -->|Yes| n15
    n14 -->|No| n16
    n15 --> n16
    n16 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[import asyncio]
    n5[from collections import defaultdict]
    n6[from collections.abc import AsyncIterator]
    n7[from contextlib import asynccontextmanager]
    n8[from dataclasses import dataclass, field]
    n9[from datetime import datetime]
    n10[from enum import Enum]
    n11[from typing import Any]
    n12[from services.aiva_common.utils import get_logger]
    n13[logger = get_logger(__name__)]
    n14[class BrowserType(...)]
    n15[class BrowserStatus(...)]
    n16[class BrowserInstance(...)]
    n17[class PageInstance(...)]
    n18[class PoolConfig(...)]
    n19[class HeadlessBrowserPool(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n19
    n19 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[import asyncio]
    n5[from dataclasses import dataclass, field]
    n6[from enum import Enum]
    n7[from typing import Any]
    n8[from services.aiva_common.utils import get_logger]
    n9[logger = get_logger(__name__)]
    n10[class InteractionType(...)]
    n11[class JsEvent(...)]
    n12[class InteractionResult(...)]
    n13[class JsInteractionSimulator(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n指紋管理器 - 負責收集、合併和管理掃描過程中的指紋信息\n']
    n4[from __future__ import annotations]
    n5[import httpx]
    n6[from services.aiva_common.schemas import Fingerpri...]
    n7[from .info_gatherer.passive_fingerprinter import P...]
    n8[class FingerprintMerger(...)]
    n9[class FingerprintCollector(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[import random]
    n5[from typing import Any]
    n6[from services.aiva_common.utils import get_logger]
    n7[logger = get_logger(__name__)]
    n8[class HeaderConfiguration(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n1 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from dataclasses import dataclass, field]
    n5[from enum import Enum]
    n6[import re]
    n7[from typing import Any]
    n8[from services.aiva_common.enums import Severity]
    n9[from services.aiva_common.utils import get_logger]
    n10[logger = get_logger(__name__)]
    n11[class SinkType(...)]
    n12[class PatternType(...)]
    n13[class SinkMatch(...)]
    n14[class PatternMatch(...)]
    n15[class AnalysisResult(...)]
    n16[class JavaScriptSourceAnalyzer(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from services.aiva_common.schemas import Fingerpri...]
    n5[class PassiveFingerprinter(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from dataclasses import dataclass, field]
    n5[import re]
    n6[from typing import Any]
    n7[from services.aiva_common.enums import Location, S...]
    n8[from services.aiva_common.utils import get_logger]
    n9[logger = get_logger(__name__)]
    n10[class SensitiveMatch(...)]
    n11[class DetectionResult(...)]
    n12[class SensitiveInfoDetector(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nJavaScript 代碼分析器\n靜態分析 JavaScript 代碼以識別潛在的...]
    n4[from __future__ import annotations]
    n5[import re]
    n6[from typing import Any]
    n7[from services.aiva_common.schemas import JavaScrip...]
    n8[from services.aiva_common.utils import get_logger,...]
    n9[logger = get_logger(__name__)]
    n10[class JavaScriptAnalyzer(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\nScan 模組專用數據合約\n定義掃描引擎相關的所有數據結構，基於 Pydantic...]
    n4[from __future__ import annotations]
    n5[from typing import Any]
    n6[from pydantic import BaseModel, Field, field_valid...]
    n7[from services.aiva_common.enums import Location, S...]
    n8[class SensitiveMatch(...)]
    n9[class JavaScriptAnalysisResult(...)]
    n10[class NetworkRequest(...)]
    n11[class InteractionResult(...)]
    n12[class DynamicScanTask(...)]
    n13[class DynamicScanResult(...)]
    n14[__all__ = ['SensitiveInfoType&#39...]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[import re]
    n5[from urllib.parse import urlparse]
    n6[from services.aiva_common.schemas import ScanScope]
    n7[from services.aiva_common.utils import get_logger]
    n8[logger = get_logger(__name__)]
    n9[class ScopeManager(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[from dataclasses import dataclass]
    n5[from enum import Enum]
    n6[from typing import Any]
    n7[from services.aiva_common.utils import get_logger]
    n8[logger = get_logger(__name__)]
    n9[class ScanStrategy(...)]
    n10[class StrategyParameters(...)]
    n11[class StrategyController(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3[from __future__ import annotations]
    n4[import json]
    n5[import time]
    n6[from services.aiva_common.enums import ModuleName,...]
    n7[from services.aiva_common.mq import get_broker]
    n8[from services.aiva_common.schemas import AivaMessa...]
    n9[from services.aiva_common.utils import get_logger,...]
    n10[from .authentication_manager import Authentication...]
    n11[from .core_crawling_engine.http_client_hi import H...]
    n12[from .core_crawling_engine.static_content_parser i...]
    n13[from .core_crawling_engine.url_queue_manager impor...]
    n14[from .fingerprint_manager import FingerprintCollec...]
    n15[from .header_configuration import HeaderConfigurat...]
    n16[logger = get_logger(__name__)]
    n17[def run(...)]
    n18[def _perform_scan(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n14
    n14 --> n15
    n15 --> n16
    n16 --> n17
    n17 --> n18
    n18 --> n2

flowchart TB
    n1([開始])
    n2([結束])
    n3['\n重構的 Scan Worker\n使用 ScanOrchestrator 進行統一的...]
    n4[from __future__ import annotations]
    n5[import json]
    n6[from services.aiva_common.enums import ModuleName,...]
    n7[from services.aiva_common.mq import get_broker]
    n8[from services.aiva_common.schemas import AivaMessa...]
    n9[from services.aiva_common.utils import get_logger,...]
    n10[from .scan_orchestrator import ScanOrchestrator]
    n11[logger = get_logger(__name__)]
    n12[def run(...)]
    n13[def _perform_scan_with_orchestrator(...)]
    n1 --> n3
    n3 --> n4
    n4 --> n5
    n5 --> n6
    n6 --> n7
    n7 --> n8
    n8 --> n9
    n9 --> n10
    n10 --> n11
    n11 --> n12
    n12 --> n13
    n13 --> n2